/*
 *  Copyright 2020-2025 the original author or authors.
 *  You cannot use this file unless authorized by the author.
 */

package org.ipig.computing.spark.streaming.kafka.impl;

import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.ipig.computing.commons.pojo.kafka.KafkaRecordInfo;
import org.ipig.computing.commons.pojo.kafka.RecordInfo;
import org.ipig.computing.spark.streaming.kafka.AbstractSparkStreamKafkaToRedisExecutor;

/**
 * Generic Spark Stream Kafka To Redis Executor实现
 *
 * @author <a href="mailto:comchnts@163.com">chinats</a>
 * @since 1.0
 */
@Slf4j
public class GenericSparkStreamKafkaToRedisExecutorImpl extends AbstractSparkStreamKafkaToRedisExecutor {

    @Override
    public void doEachRecord(KafkaRecordInfo<String, RecordInfo<JSONObject, JSONObject>> recInfo) {
        RecordInfo info = recInfo.getValue();
        System.out.println(info.toString());
    }
}